b475602be82230ad3d20da8d0b56b99f47b9d192,tools/stress/src/org/apache/cassandra/stress/operations/MultiGetter.java,MultiGetter,run,#CassandraClient#,42
Before Change
{
ColumnParent parent = new ColumnParent("Super1").setSuper_column(ByteBufferUtil.bytes("S" + j));
long start = System.currentTimeMillis();
boolean success = false;
String exceptionMessage = null;
for (int t = 0; t < session.getRetryTimes(); t++)
{
if (success)
break;
try
{
results = client.multiget_slice(keys, parent, predicate, session.getConsistencyLevel());
success = (results.size() != 0);
}
catch (Exception e)
{
exceptionMessage = getExceptionMessage(e);
}
}
if (!success)
{
error(String.format("Operation [%d] retried %d times - error on calling multiget_slice for keys %s %s%n",
index,
session.getRetryTimes(),
keys,
(exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
}
session.operations.getAndIncrement();
session.keys.getAndAdd(keys.size());
session.latency.getAndAdd(System.currentTimeMillis() - start);
offset += session.getKeysPerCall();
}
}
else
{
ColumnParent parent = new ColumnParent("Standard1");
List<ByteBuffer> keys = generateKeys(offset, offset + session.getKeysPerCall());
long start = System.currentTimeMillis();
boolean success = false;
String exceptionMessage = null;
for (int t = 0; t < session.getRetryTimes(); t++)
{
if (success)
break;
try
{
results = client.multiget_slice(keys, parent, predicate, session.getConsistencyLevel());
success = (results.size() != 0);
}
catch (Exception e)
{
exceptionMessage = getExceptionMessage(e);
success = false;
}
}
if (!success)
{
error(String.format("Operation [%d] retried %d times - error on calling multiget_slice for keys %s %s%n",
index,
session.getRetryTimes(),
keys,
(exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
}
session.operations.getAndIncrement();
session.keys.getAndAdd(keys.size());
session.latency.getAndAdd(System.currentTimeMillis() - start);
offset += session.getKeysPerCall();
}
After Change
{
ColumnParent parent = new ColumnParent("Super1").setSuper_column(ByteBufferUtil.bytes("S" + j));
TimerContext context = session.latency.time();
boolean success = false;
String exceptionMessage = null;
for (int t = 0; t < session.getRetryTimes(); t++)
{
if (success)
break;
try
{
results = client.multiget_slice(keys, parent, predicate, session.getConsistencyLevel());
success = (results.size() != 0);
}
catch (Exception e)
{
exceptionMessage = getExceptionMessage(e);
}
}
if (!success)
{
error(String.format("Operation [%d] retried %d times - error on calling multiget_slice for keys %s %s%n",
index,
session.getRetryTimes(),
keys,
(exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
}
session.operations.getAndIncrement();
session.keys.getAndAdd(keys.size());
context.stop();
offset += session.getKeysPerCall();
}
}
else
{
ColumnParent parent = new ColumnParent("Standard1");
List<ByteBuffer> keys = generateKeys(offset, offset + session.getKeysPerCall());
TimerContext context = session.latency.time();
boolean success = false;
String exceptionMessage = null;
for (int t = 0; t < session.getRetryTimes(); t++)
{
if (success)
break;
try
{
results = client.multiget_slice(keys, parent, predicate, session.getConsistencyLevel());
success = (results.size() != 0);
}
catch (Exception e)
{
exceptionMessage = getExceptionMessage(e);
success = false;
}
}
if (!success)
{
error(String.format("Operation [%d] retried %d times - error on calling multiget_slice for keys %s %s%n",
index,
session.getRetryTimes(),
keys,
(exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
}
session.operations.getAndIncrement();
session.keys.getAndAdd(keys.size());
context.stop();
offset += session.getKeysPerCall();
}